package com.galaxy.commom.base.mq;

import java.util.List;
import org.apache.rocketmq.common.message.MessageExt;

/**
 * 消息队列-消息消费处理接口
 * @author caijinbang
 * @date 2018/9/17 23:41
 */
public interface MqMsgProcessor {


  /**
   * 消息处理<br/>
   * 如果没有return true ，consumer会重新消费该消息，直到return true<br/>
   * consumer可能重复消费该消息，请在业务端自己做是否重复调用处理，该接口设计为幂等接口
   * @param topic 消息主题
   * @param tag 消息标签
   * @param msg 消息集合
   * @return
   */
  MqConsumeResult handle(String topic, String tag, List<MessageExt> msg);
}
